package com.plat.net.tcp.code;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.bytes.ByteArrayDecoder;

import java.util.List;

public class MysqlDecoder extends ByteArrayDecoder {

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception {
        System.out.println("MysqlDecoder decode");
        out.add(msg.readBytes(msg.readableBytes()));
    }
}
